# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.operators.dummy_operator import DummyOperator
from .terminal_billcode_monitor_day_1 import jms_ods__terminal_billcode_monitor_day_1
from .terminal_billcode_monitor_day_2 import jms_ods__terminal_billcode_monitor_day_2
from .terminal_billcode_monitor_day_3 import jms_ods__terminal_billcode_monitor_day_3
from .terminal_billcode_monitor_day_4 import jms_ods__terminal_billcode_monitor_day_4


jms_ods__terminal_billcode_monitor = DummyOperator(
    task_id='jms_ods__terminal_billcode_monitor',
    email=['chenhongping@yl-scm.com','yl_bigdata@yl-scm.com'],
    retries=0,
    priority_weight=0,
    sla=timedelta(hours=2),
)

jms_ods__terminal_billcode_monitor << [jms_ods__terminal_billcode_monitor_day_1,
                                       jms_ods__terminal_billcode_monitor_day_2,
                                       jms_ods__terminal_billcode_monitor_day_3,
                                       jms_ods__terminal_billcode_monitor_day_4,]
